package css.sword.annotation.kafka;

import java.util.Map;


/**
 * 缓存操作指令接口
 * @author liboyang
 *
 */
public interface OAKafkaCommands {
    /**接口
     * @param topics  参数
     * @param map 参数
     * */
    void sendkafka(String topics, Map<String, Object> map) throws Exception;
}
